package io.kiki.stack.netty.processor;

import io.kiki.stack.netty.channelManager.ChannelContext;
import io.kiki.stack.netty.command.Command;

import java.util.concurrent.Executor;

public interface Processor<T extends Command> {

    void process(ChannelContext channelContext, T msg, Executor defaultExecutor) throws Exception;

    Executor getExecutor();

    void setExecutor(Executor executor);

}
